package org.apache.seatunnel.app.test;

/**
 * @ClassName KafkaConsumerService
 * @Description
 * @Author sizegang
 * @Date2025/2/13 15:03
 **/
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class KafkaConsumerService {

    @KafkaListener(topics = "myTopic", groupId = "myGroup")
    public void listen(String message) {
        System.out.println("Received Messasge in group myGroup: " + message);
    }
}
